a4e5c8c742a1c21a3208744520a9a79f4c70919f,software/messaging/src/main/java/brooklyn/entity/zookeeper/ZooKeeperSshDriver.java,ZooKeeperSshDriver,getZookeeperServers,#,67
Before Change
String hostname = attributeWhenReady(server, ZooKeeperNode.HOSTNAME);
Integer port = attributeWhenReady(server, ZooKeeperNode.ZOOKEEPER_PORT);
Integer leaderPort = attributeWhenReady(server, ZooKeeperNode.ZOOKEEPER_LEADER_PORT);
Integer electionPort = attributeWhenReady(server, ZooKeeperNode.ZOOKEEPER_ELECTION_PORT);
result.add(new ZooKeeperServerConfig(myid, hostname, port, leaderPort, electionPort));
}
return result;
After Change
String hostname = Entities.attributeSupplierWhenReady(member, ZooKeeperNode.HOSTNAME).get();
Integer port = Entities.attributeSupplierWhenReady(member, ZooKeeperNode.ZOOKEEPER_PORT).get();
Integer leaderPort = Entities.attributeSupplierWhenReady(member, ZooKeeperNode.ZOOKEEPER_LEADER_PORT).get();
Integer electionPort = Entities.attributeSupplierWhenReady(member, ZooKeeperNode.ZOOKEEPER_ELECTION_PORT).get();
result.add(new ZooKeeperServerConfig(myid, hostname, port, leaderPort, electionPort));
}
return result;